95035a7e23b7f68b5f017e9eca507115d94e2185,src/main/java/com/englishtown/vertx/cassandra/impl/ZooKeeperCassandraConfigurator.java,ZooKeeperCassandraConfigurator,initZooKeeper,#,44
Before Change
}
if (socketOptions == null) {
promises.add(helper.getConfigElement(getPathPrefix() + "/cassandra/socket").then(
value -> {
JsonObject json = value.asJsonObject();
if (json != null) {
initSocketOptions(json);
}
return null;
}));
}
if (queryOptions == null) {
promises.add(helper.getConfigElement(getPathPrefix() + "/cassandra/query").then(
value -> {
JsonObject json = value.asJsonObject();
if (json != null) {
initQueryOptions(json);
}
return null;
}));
}
if (metricsOptions == null) {
promises.add(helper.getConfigElement(getPathPrefix() + "/cassandra/metrics").then(
value -> {
JsonObject json = value.asJsonObject();
if (json != null) {
After Change
}
if (socketOptions == null) {
promises.add(helper.getConfigElement(ZKPaths.makePath(getPathPrefix(), "socket")).then(
value -> {
JsonObject json = value.asJsonObject();
if (json != null) {
initSocketOptions(json);
}
return null;
}));
}
if (queryOptions == null) {
promises.add(helper.getConfigElement(ZKPaths.makePath(getPathPrefix(), "query")).then(
value -> {
JsonObject json = value.asJsonObject();
if (json != null) {
initQueryOptions(json);
}
return null;
}));
}
if (metricsOptions == null) {
promises.add(helper.getConfigElement(ZKPaths.makePath(getPathPrefix(), "metrics")).then(
value -> {
JsonObject json = value.asJsonObject();
if (json != null) {